#include "ProcessPool.hpp"

int main()
{
    // fun();
    
    ProcessPool pp(gdefaultnum);   //在头文件直接定义了 gdefaultnum  进程个数直接确定
    pp.Create();     //使用进程池第一件事   创建进程池   要提供对应的接口
    // pp.Debug();     //测试输出
    int task_code = 0;    //任务码   

    
    //自动派发任务
    int cnt = 10;
    //如果不想让进程一直跑   就加上一个   限制   int cnt = 10;        while(cnt--){}
    //让主进程统一进行发任务
    while(cnt--)
    {
        //1.选择一个通信的信道
        // pp.Run(task_code++);   
        pp.Run();
        sleep(1);
    }

    //当进程池创建出来之后   需要把进程池进行释放  就要有一个对应接口操作  pp.stop()
    //回收  结束进程池
    pp.StopProcessPool();

    // sleep(1000);
    return 0;
}